package com.kabu.guardedsuspension;

/**
 * @author jiawuwei
 * @Copyright: Copyright (c) 兆日科技股份有限公司  2020
 * @date 2020/7/22,11:08
 */
public class Test {
    public static void main(String[] args) {

        Thread t1 = new Thread(()->{
            Consumer consumer = new Consumer();
            while (true){
                Message message = consumer.handleWebReq();
            }
        });
        //mq收到消息后，
        Thread t2 = new Thread(()->{
            Mq mq = new Mq();
            mq.onMessage(null);
        });
    }
}
